from celery_task.task import add, send_sms

# res = add.delay(100, 1)

# celery执行延时任务
## 第一种方式：2021年1月7日22点3分12秒发送短信

from datetime import datetime

# eta:延迟多长时间执行，eta需要传时间对象,并且是utc时间

# 制作时间对象
# v1 = datetime(2021, 1, 7, 22, 12, 12)
# print(v1)
#
# v2 = datetime.utcfromtimestamp(v1.timestamp())
#
# print(v2)
# res = send_sms.apply_async(args=['18977654332', ], eta=v2)
#
# print(res)
#

from datetime import datetime
from datetime import timedelta

ctime = datetime.now()
print(ctime.timestamp())
# 转化为utc时间,utc+8 ===>时间戳===> utc
utc_ctime = datetime.utcfromtimestamp(ctime.timestamp())

time_delay = timedelta(seconds=10)  # 延迟的秒数

task_time = utc_ctime + time_delay
print(task_time)

res = send_sms.apply_async(args=['18977654332', ], eta=task_time)
# 到了这个时间执行该任务，将结果存储到db2中，所以在这个时间之后的请求可以得到任务结果。

print(res)
